# @Time : 2024/6/13 19:23
# @Author : ZHUYI
# @File : main
import sys

import producer_juejin
import consumer1_mysql
import consumer2_excel
import dataVisual

if __name__ == '__main__':
    # 定义topic
    topic = "juejin4"
    # 生产者生产消息
    producer_juejin.producer_juejin(topic)
    # 消费者1消费消息,并插入数据库
    consumer1_mysql.consumer1(topic)
    # 消费者1消费消息,并插入csv
    consumer2_excel.consumer2(topic)
    # 数据可视化
    dataVisual.dataVisual()